package activemq.topic;

public class TestTopic {

	public static void main(String[] args) throws Exception {
		Consumer consumer = new Consumer();
		Producer producer = new Producer();
		consumer.consumeMessage();
		producer.produceMessage("Hello, topic!");
		producer.close();
		consumer.close();

	}
}
